package com.cenntro.common.mq.consumer.processor;

import java.util.List;

import org.apache.rocketmq.common.message.MessageExt;

/**
 * 消息队列-消息消费处理接口
 */
public interface MQMsgProcessor {
	/**
	 * 消息处理<br/>
	 * 如果没有return true ，consumer会重新消费该消息，直到return true<br/>
	 * consumer可能重复消费该消息，请在业务端自己做是否重复调用处理，该接口设计为幂等接口
	 */
	MQConsumeResult handle(String topic, String tag, List<MessageExt> msgs);
	
	/**
	 * 重复检查
	 * @return
	 */
	Boolean repeatable();
	
}
